package com.zq.learn.spark.kafka;


/**
 * KafkaTest
 * Kafka API 测试类
 *
 * @author ZhangQi
 * @date 2020/2/10
 */
public class KafkaTest {
  public static void main(String[] args) {
    //消息发送
//    UserKafkaProducer producerThread = new UserKafkaProducer("topic1");
//    producerThread.start();
    //消息消耗
//    UserKafkaConsumer consumerThread = new UserKafkaConsumer("orderTopic");
//    consumerThread.start();
    //发送订单消息
    OrderProducer orderProducer=new OrderProducer("orderTopic");
    orderProducer.sendMsg();
  }

}
